package com.woniuxy.email;

import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.data.redis.DataRedisTest;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * @author yellow Docter
 * @date   2024-10-24   
 * @desc   蜗牛创想：www.woniuxy.com
 *
 *   测试死信队列
 */
@SpringBootTest
public class MQTest06 {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void send01(){

        /**
         * 正常发送消息 到普通队列中
         *     普通队列消费者 拒绝消息
         * 消息会进入到 普通队列中 (随后 进入到死信队列中)
         *    死信消费者消费
         *    normal.exchange
         *    city.gz
         */
        rabbitTemplate.convertAndSend("normal.exchange","city.gz","这是一条正常消息、中奖2000w");

    }
}

